﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Common.RabbitMQ
{
    public class RabbitMqService : IRabbitMqService
    {
        public RabbitMqService()
        {
                
        }

        public Task<string> ConsumeMessage(string exchange, string queueName, string routingKey, string type = "fanout")
        {
            throw new NotImplementedException();
        }

        public Task PublishMessage(string exchange, string queueName, string message, string routingKey, string type = "fanout")
        {
            throw new NotImplementedException();
        }

        public Task SubscribeMessage(string exchange, string queueName, string routingKey, Action<string> del, string type = "direct")
        {
            throw new NotImplementedException();
        }
    }
}
